var mysql = require('../config/mysql'); //获取数据库连接配置
var DB = require('../framework/DBcrud.js');



//实例化操作数据库的连接池,并指定数据库连接池和表名
if(!db){
	var db = new DB.DBcrud(mysql.test_pool,'user');
	console.log(1);	
}


/**
 * [查询语句]
 * @param  {[type]}   arr      [需要传入sql预处理的'?',以数组的形式传入]
 * @param  {Function} callback [回调函数]
 * @return 无返回值
 */
exports.select = function(arr,callback){
	db.where = '';
	db.select([],function(err,results){
		if (err) {
			callback(true);
			return;
		}else if(results!=undefined){
			//将RowDataPack对象转化为json字符串
			var jsonStr = JSON.stringify(results);
			//将json字符串转化为json数组
			var jsonObj = JSON.parse(jsonStr);
			callback(false,jsonObj);
		}else{
			callback(true);
			return;
		}
	});
}



/**
 * [添加语句]
 * @param  {[type]}   arr      [需要传入sql预处理的'?',以数组的形式传入]
 * @param  {Function} callback [回调函数]
 * @return 无返回值
 */
exports.insert = function(arr,callback){
	db.filed = 'name,sex,age,province';
	db.value = 'value(?,?,?,?)';
	db.insert(arr,function(err,results){
		if (err) {
			callback(true);
			return;
		}else if(results!=undefined){
			callback(false,results);
		}else{
			callback(true);
			return;
		}
	});
}


/**
 * [修改语句]
 * @param  {[type]}   arr      [需要传入sql预处理的'?',以数组的形式传入]
 * @param  {Function} callback [回调函数]
 * @return 无返回值
 */
exports.update = function(arr,callback){
	db.updateFiled = "name=?,sex=?,age=?,province=?";
	db.where = " where id=?"
	db.update(arr,function(err,results){
		if (err) {
			callback(true);
			return;
		}else if(results!=undefined){
			callback(false,results);
		}else{
			callback(true);
			return;
		}
	});
}


/**
 * [删除语句]
 * @param  {[type]}   arr      [需要传入sql预处理的'?',以数组的形式传入]
 * @param  {Function} callback [回调函数]
 * @return 无返回值
 */
exports.delete = function(arr,callback){
	db.where = " where id=?"
	db.delete(arr,function(err,results){
		if (err) {
			callback(true);
			return;
		}else if(results!=undefined){
			callback(false,results);
		}else{
			callback(true);
			return;
		}
	});
}




